package com.cpz.rabbitmq.message;

import com.cpz.rabbitmq.config.RabbitConstants;

/**
 * @author cpz
 * @since 2022/09/19
 */
public class TopicMessage extends RabbitMessage<String> {

    @Override
    public String exchange() {
        return RabbitConstants.EXCHANGE_TOPIC;
    }

    @Override
    public String routingKey() {
        return RabbitConstants.ROUTING_KEY_TOPIC.replace("#", "test");
    }
}
